package influxdb

import "github.com/sirupsen/logrus"

//插入数据库
func writePoints() {
	for {
		select {
		case p := <-PointsSubChan:
			err := ConnInflux.Write(p)
			if err != nil {
				logrus.Error("influx: insert failed!", err)
			}
		}
	}
}
